9fa9a7430595f5f84d1617862efc5867192f34f6,cdap-app-templates/cdap-etl/cdap-etl-core/src/test/java/co/cask/cdap/template/etl/common/TransformExecutorTest.java,TransformExecutorTest,testTransforms,#,42
Before Change
);
TransformExecutor<Integer, String> executor = new TransformExecutor<>(transforms, stageMetrics);
List<String> results = Lists.newArrayList(executor.runOneIteration(1));
Assert.assertTrue(results.isEmpty());
Assert.assertEquals(3, mockMetrics.getCount("source.first.1.records.out"));
Assert.assertEquals(0, mockMetrics.getCount("transform.second.2.records.out"));
After Change
TransformExecutor<Integer, String> executor = new TransformExecutor<>(transforms);
TransformResponse transformResponse = executor.runOneIteration(1);
List<String> results = Lists.newArrayList(transformResponse.getEmittedRecords());
Assert.assertTrue(results.isEmpty());
Map<String, Collection> errorIteratorsMap = transformResponse.getMapTransformIdToErrorEmitter();